| 【Redis】Redisson入门以及Redisson可重入锁的lua脚本实现 | 您所在的位置：网站首页 › redisson golang › 【Redis】Redisson入门以及Redisson可重入锁的lua脚本实现 |
【Redis】Redisson入门以及Redisson可重入锁的lua脚本实现
|
目录 一、Redisson介绍 二、Redisson的入门 1、引入依赖 2、配置客户端 3、使用锁 三、Redisson可重入锁的原理 1、原理 2、实现 3、lua脚本保证原子性 1.获取锁 2.释放锁 一、Redisson介绍在之前的文章里我们通过redis中的setn实现了一个简单的分布式锁以及解决了误删、原子性等问题，但他依旧存在不足。我们在项目中一般使用比较成熟的分布式锁，Redisson是一个在redis基础上实现的Java驻内存数据网格，他不仅提供了一系列分布式的常用Java对象，他还提供了许多分布式服务，就比如分布式锁，Redisson中的分布式锁则不存在上述的问题，我们在项目中完全可使用 二、Redisson的入门 1、引入依赖首先我们需要在项目的pom文件中引入对应的依赖 org.redisson redisson 3.13.6 2、配置客户端其次我们需要创建一个配置类来进行客户端的配置 package com.example.demo.config; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; @Configuration public class RedisConfig { @Bean public RedissonClient redissonClient() { Config config = new Config(); config.useSingleServer().setAddress("redis://IP:6379").setPassword("密码"); return Reisson.create(config); } } 3、使用锁其次我们就可以在项目中进行使用了 package com.example.demo.config; import org.springframework.beans.factory.annotation.Autowired; import java.util.concurrent.TimeUnit; public class Use { @Autowired private RedissonClient redis; public void test() { // 获取锁 RLock lock = redis.getLock("name"); // 尝试获取锁： 参数1 最大等待时间 参数2 锁自动释放时间 参数3 时间单位 boolean isLock = lock.tryLock(1,111, TimeUnit.SECONDS); if (!isLock) { try { // 业务代码 } finally { lock.unlock(); } } } } 三、Redisson可重入锁的原理 1、原理线程1在方法1中获取到了锁，此时在redis锁中会记录持有这把锁的线程，然后执行方法1，在方法1中调用了方法2，进入方法2后发现方法2也需要获取锁，此时线程在获取锁时发现这个锁已经被获取了，此时就进行判断，如果发现是自己获取了这把锁，这直接进入执行业务，但是方法2执行完释放锁时，此时锁并不是真正的释放还需要去执行完方法1所剩的业务才可以释放，为了解决提前释放锁的问题，在实现时会维护一个计数器，当线程获取到锁后计算器会进行加1，当再次进入时计数器再加1变为2，此时方法2执行完释放锁计数器-1，此时计数器不为0则重置锁的过期时间不删除，当计数器=0时说明锁真正释放，删除锁 2、实现在redis中实现可重入锁时需要维护一个计数器字段，但是传统的string类型是没有办法做到的，此时我们可以使用redis中的hash类型
在获取锁时我们先要判断锁是否存在，不存在则插入数据直接获取锁，如果存在则需要判断这把锁是不是自己持有，如果是则需要使得计数器+1，如果我们在Java中提供代码去一条一条的执行时，这些操作并不是原子性的，会带来线程安全问题（前面有提到）所以我们必须保证这些操作是原子性的，我们可以通过lua脚本来实现 【Redis】实现及优化分布式锁：实现、解决误删锁问题以及lua脚本确保redis操作原子性_1373i的博客-CSDN博客 释放锁时，我们先要判断锁是不是自己的，如果是自己的则让计数器-1，然后再判断计数器是否为0，如果为0则删除锁，这些操作也需要保证原子性 local key = KEYS[1] -- 锁的key local threadId = ARGV[1] -- 线程标识 local time = ARGV[2] -- 锁的ttl -- 判断锁是否是自己的 if (redis.call('hexists',key) == 0) then -- 不是自己的直接返回 return nil; end; -- 说明锁是自己的计数器-1 local count = redis.call('hincrby',key,threadId,-1); -- 判断计数器是否为0 if (count > 0) then -- 说明不能释放锁，重置有效期 redis.call('expire',key,time); return nil; else -- 说明可以释放 redis.call('del',key); -- 删除 end |
https://blog.csdn.net/qq_61903414/article/details/130631441?spm=1001.2014.3001.5501【本文地址】